// import 'dart:convert';
//
// import 'package:web_socket_channel/web_socket_channel.dart';
//
// import '../model/chat_message.dart';
//
// class WebSocketService {
//   WebSocketChannel? _channel;
//
//   void connect(String userId) {
//     _channel = WebSocketChannel.connect(
//       Uri.parse('ws://yourserver/ws?userId=$userId'),
//     );
//
//     _channel!.stream.listen(
//       (message) {
//         final data = jsonDecode(message);
//         // 分发消息
//       },
//       onDone: () {
//         // 尝试重连
//       },
//       onError: (e) {
//         // 处理错误
//       },
//     );
//   }
//
//   void send(ChatMessage msg) {
//     final jsonMsg = jsonEncode(msg.toJson());
//     _channel?.sink.add(jsonMsg);
//   }
//
//   void dispose() {
//     _channel?.sink.close();
//   }
// }
